- appendLiteral
void appendLiteral(HttpWriteBuffer buffer, T[] data)
Undocumented in source. Be warned that the author may not have intended to support it.
- createStream
StreamID createStream()
Undocumented in source. Be warned that the author may not have intended to support it.
- detach
void detach(HTTPTransaction txn)
Undocumented in source. Be warned that the author may not have intended to support it.
- generateBody
size_t generateBody(HTTPTransaction txn, HttpWriteBuffer chain, ubyte[] data, bool eom)
Undocumented in source. Be warned that the author may not have intended to support it.
- generateChunkHeader
size_t generateChunkHeader(HTTPTransaction txn, HttpWriteBuffer buffer, size_t length)
Undocumented in source. Be warned that the author may not have intended to support it.
- generateChunkTerminator
size_t generateChunkTerminator(HTTPTransaction txn, HttpWriteBuffer buffer)
Undocumented in source. Be warned that the author may not have intended to support it.
- generateEOM
size_t generateEOM(HTTPTransaction txn, HttpWriteBuffer buffer)
Undocumented in source. Be warned that the author may not have intended to support it.
- generateHeader
size_t generateHeader(HTTPTransaction txn, HTTPMessage msg, HttpWriteBuffer buffer, bool eom)
Undocumented in source. Be warned that the author may not have intended to support it.
- generateRstStream
size_t generateRstStream(HTTPTransaction txn, HttpWriteBuffer buffer, HTTPErrorCode code)
Undocumented in source. Be warned that the author may not have intended to support it.
- getProtocol
CodecProtocol getProtocol()
Undocumented in source. Be warned that the author may not have intended to support it.
- getTransportDirection
TransportDirection getTransportDirection()
Undocumented in source. Be warned that the author may not have intended to support it.
- isBusy
bool isBusy()
Undocumented in source. Be warned that the author may not have intended to support it.
- onBody
void onBody(HTTPParser parser, ubyte[] data, bool finish)
Undocumented in source. Be warned that the author may not have intended to support it.
- onChunkComplete
void onChunkComplete(HTTPParser parser)
Undocumented in source. Be warned that the author may not have intended to support it.
- onChunkHeader
void onChunkHeader(HTTPParser parser)
Undocumented in source. Be warned that the author may not have intended to support it.
- onConnectClose
void onConnectClose()
Undocumented in source. Be warned that the author may not have intended to support it.
- onHeaderField
void onHeaderField(HTTPParser parser, ubyte[] data, bool finish)
Undocumented in source. Be warned that the author may not have intended to support it.
- onHeaderValue
void onHeaderValue(HTTPParser parser, ubyte[] data, bool finish)
Undocumented in source. Be warned that the author may not have intended to support it.
- onHeadersComplete
void onHeadersComplete(HTTPParser parser)
Undocumented in source. Be warned that the author may not have intended to support it.
- onIngress
size_t onIngress(ubyte[] buf)
Undocumented in source. Be warned that the author may not have intended to support it.
- onMessageBegin
void onMessageBegin(HTTPParser )
Undocumented in source. Be warned that the author may not have intended to support it.
- onMessageComplete
void onMessageComplete(HTTPParser parser)
Undocumented in source. Be warned that the author may not have intended to support it.
- onStatus
void onStatus(HTTPParser parser, ubyte[] data, bool finish)
Undocumented in source. Be warned that the author may not have intended to support it.
- onTimeOut
void onTimeOut()
Undocumented in source. Be warned that the author may not have intended to support it.
- onUrl
void onUrl(HTTPParser parser, ubyte[] data, bool finish)
Undocumented in source. Be warned that the author may not have intended to support it.
- responseBodyMustBeEmpty
bool responseBodyMustBeEmpty(ushort status)
Undocumented in source. Be warned that the author may not have intended to support it.
- setCallback
void setCallback(CallBack callback)
Undocumented in source. Be warned that the author may not have intended to support it.
- setParserPaused
void setParserPaused(bool paused)
Undocumented in source. Be warned that the author may not have intended to support it.
- shouldClose
bool shouldClose()
Undocumented in source. Be warned that the author may not have intended to support it.
- StreamID
alias StreamID = uint
Key that uniquely identifies a request/response pair within
(and only within) the scope of the codec. Code outside the
codec should regard the StreamID as an opaque data
structure; different subclasses of HTTPCodec are likely to
use different conventions for generating StreamID values.
- CallBack
interface CallBack
Undocumented in source.
- getProtocol
CodecProtocol getProtocol()
Undocumented in source.
- createStream
StreamID createStream()
Undocumented in source.
- getTransportDirection
TransportDirection getTransportDirection()
Get the transport direction of this codec:
DOWNSTREAM if the codec receives requests from clients or
UPSTREAM if the codec sends requests to servers.
- supportsStreamFlowControl
bool supportsStreamFlowControl()
Returns true iff this codec supports per stream flow control
- supportsSessionFlowControl
bool supportsSessionFlowControl()
Returns true iff this codec supports session level flow control
- setCallback
void setCallback(CallBack callback)
Set the callback to notify on ingress events
@param callback The callback object
- isBusy
bool isBusy()
Check whether the codec still has at least one HTTP
stream to parse.
- shouldClose
bool shouldClose()
Undocumented in source.
- setParserPaused
void setParserPaused(bool paused)
Pause or resume the ingress parser
@param paused Whether the caller wants the parser to be paused
- onIngress
size_t onIngress(ubyte[] buf)
Parse ingress data.
@param buf A single IOBuf of data to parse
@return Number of bytes consumed.
- onConnectClose
void onConnectClose()
Undocumented in source.
- onTimeOut
void onTimeOut()
Undocumented in source.
- detach
void detach(HTTPTransaction txn)
Undocumented in source.
- generateHeader
size_t generateHeader(HTTPTransaction txn, HTTPMessage msg, HttpWriteBuffer buffer, bool eom)
Write an egress message header. For pushed streams, you must specify
the assocStream.
@retval size the size of the generated message, both the actual size
and the size of the uncompressed data.
@return None
- generateBody
size_t generateBody(HTTPTransaction txn, HttpWriteBuffer chain, ubyte[] data, bool eom)
Write part of an egress message body.
- generateChunkHeader
size_t generateChunkHeader(HTTPTransaction txn, HttpWriteBuffer buffer, size_t length)
Write a body chunk header, if relevant.
- generateChunkTerminator
size_t generateChunkTerminator(HTTPTransaction txn, HttpWriteBuffer buffer)
Write a body chunk terminator, if relevant.
- generateEOM
size_t generateEOM(HTTPTransaction txn, HttpWriteBuffer buffer)
Generate any protocol framing needed to finalize an egress
message. This method must be called to complete a stream.
- generateRstStream
size_t generateRstStream(HTTPTransaction txn, HttpWriteBuffer buffer, HTTPErrorCode code)
Generate any protocol framing needed to abort a connection.
@return number of bytes written
- generateWsFrame
size_t generateWsFrame(HTTPTransaction txn, HttpWriteBuffer buffer, OpCode code, ubyte[] data)
Undocumented in source. Be warned that the author may not have intended to support it.
- getProtocolFormString
CodecProtocol getProtocolFormString(string str)
Undocumented in source. Be warned that the author may not have intended to support it.